a372354a3cb65a4de88a1bdc4413940c6cec32f0,app-fabric/src/main/java/org/apache/hadoop/mapred/LocalJobRunnerWithFix.java,Job,statusUpdate,#TaskAttemptID#TaskStatus#,535

Before Change


        status.setMapProgress(partialProgress / numTasks);
      } else {
        reduceCounters = taskStatus.getCounters();
        status.setReduceProgress(taskStatus.getProgress());
      }

      // ignore phase

After Change


        int reduceTaskIndex = taskId.getTaskID().getId();
        float numTasks = (float) this.numReduceTasks;

        partialReduceProgress[reduceTaskIndex] = taskStatus.getProgress();
        reduceCounters[reduceTaskIndex] = taskStatus.getCounters();

        float partialProgress = 0.0f;